package Z_DeadLine;

import com.rabbitmq.client.Channel;
import utils.RabbitMQUtils;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;

/**
 * @author： pang-yun
 * @date： 2021-12-22 11:26
 * 功能目的 ：用于
 */

public class DeadProducer {
    public static void main(String[] args) throws IOException, TimeoutException {
        Channel channel = RabbitMQUtils.getChannel();
        //----注意 交换机在consumer已经声明之后， 已经存在  不能重复声明 会产生异常

        // 发消息

        //-------------死信消息  设置 TTL时间
//        AMQP.BasicProperties build = new AMQP.BasicProperties().builder().expiration("10000").build();
        for (int i = 0; i < 10; i++) {
            String message = "message :"+i;
            channel.basicPublish(DeadLineConst.NORMAL_EXCHANGE,DeadLineConst.NORMAL_ROUTE_KEY,null,message.getBytes(StandardCharsets.UTF_8));
        }
    }
}
